package DataStreamApi.Transformation算子.物理分区算子;



import org.apache.flink.api.common.functions.Partitioner;


/**
 *将所有数据汇总到第一个子任务
 */
public class Flink05_Partitioner implements Partitioner<String> {


    @Override
    public int partition(String key, int numPartitions) {
        return 0;
    }
}
